package com.ityuwen.mengyagushi.album.listener;

import com.alibaba.fastjson.JSON;
import org.apache.commons.lang3.StringUtils;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class MaxwellListener {

    @KafkaListener(topics = "maxwell")
    public void listen(String json){
        if (StringUtils.isBlank(json)){
            return;
        }
        // 反序列化
        MaxwellObj maxwellObj = JSON.parseObject(json, MaxwellObj.class);
//        if ()
    }
}
